package etl

import org.apache.spark.sql.SparkSession

/**
  * 通过spark计算出所有独立设备标识号，充值次数在5次以上的 次数和充值金额，
  * 并保存在hdfs的一个目录 可以叫/blackmac（要求有今天的时间（年月日）,设备标识号,充值次数,充值金额）,
  * 这些就是黑卡信息
  */

object Chargethan5Times {

  def main(args: Array[String]): Unit = {

    val session = SparkSession.builder().master("local[*]").appName("统计充值次数大于5的次数和金额").getOrCreate()


  }

}
